package com.sh.data.engine.application.model.dto.datadev;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

import java.util.List;

@Data
@Schema
public class FlinkTopicResponse {

    @Schema(description = "topic")
    private String topic;

    @Schema(description = "字段")
    private List<Field> fields;

    @Data
    public static class Field {

        @Schema(description = "关键字")
        private String key;

        @Schema(description = "字段名")
        private String fieldName;

        @Schema(description = "字段取值表达式")
        private String fieldExpress;

        @Schema(description = "字段类型（从db中读取到的）")
        private String fieldType;

        @Schema(description = "字段描述")
        private String fieldDesc;
    }
}
